package org.niit.controller


import org.apache.spark.streaming.dstream.DStream
import org.niit.bean.AdClickData
import org.niit.service. MengTimeService

class MengTimeController {

  // BlackListController  应该起名是 UserAdController ,但凡是以用户角度对广告分析应该放到该Controller
  // AreaCityAdController  是以区域 城市的角度对广告分析
  private val mengTimeService = new MengTimeService

  def dispatch(data: DStream[AdClickData]): Unit = {
    mengTimeService.dataAnalysis(data) //调用相应的Service模块

  }

}